package com.example.publish_model.pushorpull;

import com.example.common.mvvm.repository.BaseRepository;
import com.example.network_skd.BaseEntity;
import com.example.network_skd.SingletonRetrofit;

import java.util.Map;

import io.reactivex.Observable;

public class SendMsgRepository extends BaseRepository {
    public Observable<BaseEntity> sendMsg(Map<String,Object> map){
        Observable<SendMsgEntity> sendMsgEntityObservable = SingletonRetrofit.getInstance()
                .getRetrofit()
                .create(ApiServer.class)
                .sendMsg(createBody(map));

        return checkNetWork(sendMsgEntityObservable);
    }
}
